package com.lichao.FinkDataProcess.sink;

import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;

import java.io.Serializable;

/**
 * @author: li chao
 * @Desc:
 * @create: 2024-11-22 16:30
 **/
public abstract class ParallelismFunction extends RichSinkFunction<String> implements Serializable {
    public int parallelism;

    public ParallelismFunction(int parallelism) {
        this.parallelism = parallelism;
    }
}
